package com.haotian.kafka;

import org.apache.kafka.clients.consumer.KafkaConsumer;
import org.apache.kafka.clients.producer.KafkaProducer;

final class KafkaFactory {

	static KafkaProducer<String, String> createProducer(_KafkaConfig config) {
		return new KafkaProducer<>(config.getProducer_props());
	}
	
	static KafkaConsumer<String, String> createConsumer(_KafkaConfig config) {
		return new KafkaConsumer<>(config.getConsumer_props());
	}

}
